76b17d4ec609d33e3e93457c272cfc806cc7d377,app-fabric/src/main/java/com/continuuity/app/guice/AppFabricServiceRuntimeModule.java,AppFabricServiceRuntimeModule,getDistributedModules,#,135
Before Change
public Module getDistributedModules() {
return Modules.combine(new AppFabricServiceModule(),
new AbstractModule() {
@Override
protected void configure() {
bind(SchedulerService.class).to(DistributedSchedulerService.class).in(Scopes.SINGLETON);
bind(Scheduler.class).to(SchedulerService.class);
MapBinder<String, ReactorServiceManager> mapBinder = MapBinder.newMapBinder(
binder(), String.class, ReactorServiceManager.class);
mapBinder.addBinding(Constants.Service.LOGSAVER).to(LogSaverServiceManager.class);
mapBinder.addBinding(Constants.Service.TRANSACTION).to(TransactionServiceManager.class);
mapBinder.addBinding(Constants.Service.METRICS_PROCESSOR).to(
MetricsProcessorServiceManager.class);
mapBinder.addBinding(Constants.Service.METRICS).to(MetricsServiceManager.class);
mapBinder.addBinding(Constants.Service.APP_FABRIC_HTTP).to(
InMemoryReactorServiceManager.class);
mapBinder.addBinding(Constants.Service.STREAMS).to(StreamServiceManager.class);
mapBinder.addBinding(Constants.Service.DATASET_EXECUTOR).to(
DatasetExecutorServiceManager.class);
}
});
}
/**
* Guice module for AppFabricServer. Requires data-fabric related bindings being available.
After Change
public Module getDistributedModules() {
return Modules.combine(new AppFabricServiceModule(),
new AbstractModule() {
@Override
protected void configure() {
bind(SchedulerService.class).to(DistributedSchedulerService.class).in(Scopes.SINGLETON);
bind(Scheduler.class).to(SchedulerService.class);
}
});
}
/**
* Guice module for AppFabricServer. Requires data-fabric related bindings being available.